package com.examples.mysql2mysql.binlog;

import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

import java.time.LocalDateTime;

public class CustomSink extends RichSinkFunction<String> {

    @Override
    public void invoke(String value, Context context) throws Exception {
        System.out.println("监听到活动数据" + LocalDateTime.now() + value);
    }
}
